package com.dmp.storm.bolt;

import java.util.Map;

import static com.dmp.storm.base.BaseMapKey.MAPKEY_RESULTMAP_BOLTMSG;

/** 
 * @author  sunzy 
 * @date 2016年2月24日 下午2:18:40 
 * @version 1.0 
 *
 * @desc 
 */
public class TestBolt extends BaseMapBolt {

	private static final long serialVersionUID = 1L;

	@Override
	public Map<String, Object> process(Map<String, Object> map) {
		String a = (String)map.get(MAPKEY_RESULTMAP_BOLTMSG);
		
		if(a != null){
			System.err.println("process:" + a);
		}else{
			System.out.println("null");
		}
		return null;
	}
}
